package com.hexinfo.dmpro.sparing.service;


import cn.hutool.core.io.file.FileAppender;
import com.hexinfo.dmpro.sparing.dto.TableDistCPDTO;

/**
 * DistCP操作类
 * 针对所有java调用sh脚本启动DistCP方式
 *
 */
public interface AsyncDropDataService {

    void execShell(String dropSql,String souName,int sizes,FileAppender heatlog);

    void updateEndFlag(String souName,Boolean state);

    Boolean getEndFlag(String souName);

    void deleteEndFlag(String souName);

    void updateTaskState(String souName,Boolean state);

    Boolean getTaskState(String souName);

    void deleteTaskState(String souName);

}
